type google.golang.org/grpc/internal/transport.http2Server
33 uses
google.golang.org/grpc/internal/transport (current package)
http2_server.go#L76: type http2Server struct {
http2_server.go#L260: t := &http2Server{
http2_server.go#L377: func (t *http2Server) operateHeaders(ctx context.Context, frame *http2.MetaHeadersFrame, handle func(*ServerStream)) error {
http2_server.go#L639: func (t *http2Server) HandleStreams(ctx context.Context, handle func(*ServerStream)) {
http2_server.go#L704: func (t *http2Server) getStream(f http2.Frame) (*ServerStream, bool) {
http2_server.go#L722: func (t *http2Server) adjustWindow(s *ServerStream, n uint32) {
http2_server.go#L732: func (t *http2Server) updateWindow(s *ServerStream, n uint32) {
http2_server.go#L743: func (t *http2Server) updateFlowControl(n uint32) {
http2_server.go#L765: func (t *http2Server) handleData(f *parsedDataFrame) {
http2_server.go#L828: func (t *http2Server) handleRSTStream(f *http2.RSTStreamFrame) {
http2_server.go#L843: func (t *http2Server) handleSettings(f *http2.SettingsFrame) {
http2_server.go#L876: func (t *http2Server) handlePing(f *http2.PingFrame) {
http2_server.go#L925: func (t *http2Server) handleWindowUpdate(f *http2.WindowUpdateFrame) {
http2_server.go#L945: func (t *http2Server) checkForHeaderListSize(hf []hpack.HeaderField) bool {
http2_server.go#L968: func (t *http2Server) writeEarlyAbort(streamID uint32, contentSubtype string, stat *status.Status, httpStatus uint32, rst bool) {
http2_server.go#L1001: func (t *http2Server) streamContextErr(s *ServerStream) error {
http2_server.go#L1011: func (t *http2Server) writeHeader(s *ServerStream, md metadata.MD) error {
http2_server.go#L1040: func (t *http2Server) writeHeaderLocked(s *ServerStream) error {
http2_server.go#L1079: func (t *http2Server) writeStatus(s *ServerStream, st *status.Status) error {
http2_server.go#L1150: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
http2_server.go#L1187: func (t *http2Server) keepalive() {
http2_server.go#L1281: func (t *http2Server) Close(err error) {
http2_server.go#L1307: func (t *http2Server) deleteStream(s *ServerStream, eosReceived bool) {
http2_server.go#L1328: func (t *http2Server) finishStream(s *ServerStream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
http2_server.go#L1352: func (t *http2Server) closeStream(s *ServerStream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
http2_server.go#L1372: func (t *http2Server) Drain(debugData string) {
http2_server.go#L1386: func (t *http2Server) outgoingGoAwayHandler(g *goAway) (bool, error) {
http2_server.go#L1442: func (t *http2Server) socketMetrics() *channelz.EphemeralSocketMetrics {
http2_server.go#L1449: func (t *http2Server) incrMsgSent() {
http2_server.go#L1456: func (t *http2Server) incrMsgRecv() {
http2_server.go#L1463: func (t *http2Server) getOutFlowWindow() int64 {
http2_server.go#L1479: func (t *http2Server) Peer() *peer.Peer {
logging.go#L30: func prefixLoggerForServerTransport(p *http2Server) *internalgrpclog.PrefixLogger {